docker exec -it kafka bash

# 创建订单事件主题
kafka-topics.sh --create --topic order-events --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
# 创建用户行为主题
kafka-topics.sh --create --topic user-behaviors --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
# 创建支付事件主题
kafka-topics.sh --create --topic payment-events --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
# 创建物流事件主题
kafka-topics.sh --create --topic logistics-events --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

# 查看 Topic 列表
kafka-topics.sh --list --bootstrap-server localhost:9092

